草庐IT

kubernetes 上的 Redis json

全部标签

ubuntu - 完成作业不稳定的 Kubernetes 集群;充满 "http2: no cached connection was available"的 kubelet 日志

总结我有各种单节点Kubernetes集群,这些集群在累积约300个已完成的作业后变得不稳定。例如,在一个集群中,有303个已完成的作业:root@xxxx:/home/xxxx#kubectlgetjobs|wc-l303观察我观察到的是kubelet日志中充满了这样的错误消息:kubelet[877]:E021909:06:14.637045877reflector.go:134]object-"default"/"job-162273560":无法列出*v1.ConfigMap:获取https://172.13.13.13:6443/api/v1/namespaces/defau

go - Kubernetes client-go Remotecommand Stream 何时完成?

我在这里使用这个远程命令https://github.com/kubernetes/client-go/blob/master/tools/remotecommand/remotecommand.go#L108在pod上执行命令并将结果流式传输到io.Writer。如上面命令中所述,链接中的函数仅在客户端或服务器断开连接时Stream才完成。由于Stream配置只附加了一个命令,为什么当命令退出时它不关闭?我怎么知道命令何时完成?特别是我正在将tar-cf-...的结果传输到客户端并想知道它何时完成。 最佳答案 我注意到Stream

go - 在 golang 中收集 Kubernetes 指标

我正在使用GKE平台来实现Kubernetes调度程序。我正在使用PrometheusGrafana来监控应用程序。为了在golang中实现调度程序,我需要获取指标作为调度程序的输入。请给我一些建议。另外请建议适当的文档,以便我可以轻松理解这些内容。我是新手,所以我什么都不知道。我们将不胜感激。 最佳答案 首先,我鼓励您阅读一些有关Kubernetes监控的相关文档architecture其中解释了很多关于Kubernetes指标主要概念的有用信息。由于您使用了Prometheus作为主要的监控集群代理,您可能会使用Kubernet

go - 为什么错误类型上的类型开关不起作用?

代码:typebaseStructstruct{valueint}typemyStructbaseStructfunccheckType(valueinterface{}){switchvalue.(type){casemyStruct:fmt.Printf("%visamyStruct\n",value)default:fmt.Printf("%vissomethingelse\n",value)}}funcmain(){checkType(*new(baseStruct))checkType(myStruct(*new(baseStruct)))}输出如下:{0}issomethi

go - kubernetes API中是否有通过注解获取所有服务的函数

我正在设置一个kubernet集群来部署我们的容器应用程序。应用程序实际上需要所有标签,但标签超过63个字符,我得到一个error.这使我依赖于注释。服务的注释如下所示:com.example.development.london/component.proxy-config.secure-routes.backend.proxy-path。/仅用于绕过RFC域错误。在Golang应用程序中,请求命名空间的所有服务。实际上基于标签。为此,到目前为止我使用了以下代码。func(kc*KubernetesCollector)generateRoutes(errorChannelchan但是

docker - 从远程机器访问托管在 digital ocean 水滴上的容器化 API

我正在尝试连接到DigitalOceanDockerDroplet上的docker-compose部署服务堆栈。它包含一个带有数据库的MySQL容器和一个带有API的go/alpine容器。我正在使用2个容器连接到的自定义桥接网络。当尝试在我的mac上本地部署堆栈并通过localhost:port访问API容器时,也会出现此问题。我没有使用docker-machine,因为我认为它只用于多主机部署。堆栈部署成功。服务器容器似乎能够连接到数据库容器。我想知道问题是否在主机的防火墙规则之内?我确实尝试在我的机器上运行mysql服务器的情况下在本地运行该应用程序并且它确实有效,所以我认为原因

go - 从 Mutating Admission Controller 中创建一个新的 Kubernetes 对象

MutatingAdmissionController可以通过连接到api-server来更新/创建另一个对象吗?我看到我们可以使用JSONPatch通过AdmissionReview改变入站对象,但我可以扩展它来创建一个完全不同的对象吗?谢谢!!-斯雷尼 最佳答案 您可以创建一个mutatingwebhookconfigurations,它基本上将服务Hook到mutatingadmissioncontroller。这就是istio向所有启用了istio注入(inject)的pod注入(inject)sidecar代理的方式。可以

go - golang在kubernetes上创建监视程序/ Controller ,以将sidecar容器附加到具有PVC附件的任何pod/部署中

我是个新手,想把上面的事情做完。最简单的方法是什么?我要找的是:1-部署观察者2-更新/删除/添加部署时,将附加一个侧车(修补部署)3-控制来自侧车的反馈。任何参考都有帮助 最佳答案 我建议你看看webhooks这样你就不会重新发明轮子了。webhook可用于拦截对api服务器的资源(包括部署)更新/删除/创建请求。然后,可以根据您的目标修改或拒绝这些请求。 关于go-golang在kubernetes上创建监视程序/Controller,以将sidecar容器附加到具有PVC附件的任何

go - Windows 上的 VIM-Go Debugger 结果为 "Goroutine not found"

我正在Windows上设置一个vim-go环境,大部分情况下都可以正常工作。我无法开始工作的一件事是调试器。我用:GoDebugStart启动它。这已经导致了很多关于debuglayer=rpc的错误。然后我在尝试创建断点时遇到更多与rpc相关的错误。最后,当开始使用:GoDebugNext进行调试时,它会提示Goroutinenotfound。有没有人有任何类似的问题或知道这可能是什么或缺少什么?谢谢!这是一些错误输出:ERR:2019-09-24T16:43:37+02:00infolayer=debuggerlaunchingprocesswithargs:[C:\Users\h

google-app-engine - App Engine Datastore 上的 Golang - 使用 PutMulti 提高性能

我有一个应该能够处理数百个并发请求的GAEGolang应用程序,对于每个请求,我都会对输入进行一些处理,然后将其存储在数据存储区中。使用任务队列(appengine/delaylib)我获得了相当不错的性能,但是为每个请求执行单行插入似乎仍然非常低效(即使插入是使用任务队列延迟的)。如果这不是应用引擎,我可能会将输出附加到一个文件中,并且每隔一段时间我会使用cron作业/其他类型的计划服务将文件批量加载到数据库中。所以我的问题是:是否有我可以在AppEngine上实现的等效方案?我曾是思考-也许我应该将一些行写入memecache,并且然后每隔几秒钟我将批量加载所有行那里并清除缓存。这